package com._119yn.host.gst200.mqtt;

import org.springframework.integration.annotation.Gateway;
import org.springframework.integration.annotation.MessagingGateway;
import org.springframework.messaging.Message;

@MessagingGateway
public interface MqttMessageSender {

    @Gateway(requestChannel = MqttChannels.MQTT_HOST_SIGNAL_MESSAGE_CHANNEL)
    void sendHostSignal(Message<?> message);

    @Gateway(requestChannel = MqttChannels.MQTT_HOST_CONTROL_ACK_MESSAGE_CHANNEL)
    void sendHostControlAck(Message<?> message);

}
